1f58affc13fab1ecce1fe4d0ebae80c294b7776a,src/main/java/com/metamx/common/guava/LimitedSequence.java,LimitedYielder,next,#OutType#,58
Before Change
{
final Yielder<OutType> next = subYielder.next(initValue);
if (! limitedAccumulator.withinThreshold()) {
return Yielders.done(next.get(), next);
}
return new LimitedYielder<OutType>(LimitedYielder.this, limitedAccumulator);
}
After Change
public Yielder<OutType> next(OutType initValue)
{
if (!limitedAccumulator.withinThreshold()) {
return Yielders.done(initValue, subYielder);
}
Yielder<OutType> next = subYielder.next(initValue);
if (!limitedAccumulator.withinThreshold() && (!limitedAccumulator.yielded()
|| limitedAccumulator.isInterruptYield())) {
next = Yielders.done(next.get(), next);
}
return new LimitedYielder<OutType>(next, limitedAccumulator);
}